package com.woniuxy.email;

import org.junit.jupiter.api.Test;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

/**
 * @author yellow Docter
 * @date 2024-10-23
 * @desc 蜗牛创想：www.woniuxy.com
 */
@SpringBootTest
public class MQTest01 {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void send01(){

        //参数1： 队列   参数2： 数据
        rabbitTemplate.convertAndSend("simple.queue", "hello world1111");

    }

    @Test
    public void send02(){

        /**
         *
         * receiveAndConvert                        接受消息
         *    主动去查询 拉取消息
         *
         * @RabbitListener(queues = "email.queue")  接受消息
         *    监听 有消息就直接消费
         */

//        //接受消息
//        String message = (String) rabbitTemplate.receiveAndConvert("simple.queue");
//        System.out.println("message = " + message);

    }

    /**
     * 测试 工作队列模型
     */
    @Test
    public void send03(){

        //参数1： 队列   参数2： 数据
        for (int i = 1; i <= 6; i++) {
            rabbitTemplate.convertAndSend("simple.queue", "hello " + i);
        }

    }
}
